java - KafkaConsumer 0.10 Java API 错误信息 : No current assignment for partition